59507381c8c725e28b2978641e638b7c7931f4e9,tests/com/comcast/cmb/test/tools/CQSTestUtils.java,CQSTestUtils,getQueueCount,#String#,49
Before Change
private static void getQueueCount(String queueUrl) throws NoSuchAlgorithmException, UnsupportedEncodingException {
int numberOfPartitions = CMBProperties.getInstance().getCQSNumberOfQueuePartitions();
CassandraPersistence persistence = new CassandraPersistence(CMBProperties.getInstance().getCQSKeyspace());
String queueHash = Util.hashQueueUrl(queueUrl);
long messageCount = 0;
for (int i=0; i<numberOfPartitions; i++) {
After Change
private static void getQueueCount(String queueUrl) throws NoSuchAlgorithmException, UnsupportedEncodingException {
int numberOfPartitions = CMBProperties.getInstance().getCQSNumberOfQueuePartitions();
AbstractCassandraPersistence cassandraHandler = CassandraPersistenceFactory.getInstance(CMBProperties.getInstance().getCQSKeyspace());
String queueHash = Util.hashQueueUrl(queueUrl);
long messageCount = 0;
for (int i=0; i<numberOfPartitions; i++) {